package com.wms.consumer.controller;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

/**
 * Description: TODO 消费者接收消息 - 标签过滤消息
 *
 * @version 1.0
 * @author: wangqiang
 * @date: 2023/3/12 23:41
 */
@Component
@Slf4j
@RocketMQMessageListener(selectorExpression = "TAG-A||TAG-B",topic = "tag_topic",consumerGroup = "tag_group")
public class TagConsumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String s) {
        log.info("消费者接收-信息...{}",s);
    }
}
